import {createServer, Socket} from 'net'
import { WSRPCServer } from '@ctsy/ws-rpc-server';
// 创建一个服务端
const server = createServer()
//创建一个链接对象
let socks:{[index:string]:Socket}={};
// 有新的连接建立的回调
server.on('connection',(sock)=>{
    sock.on('data',(data)=>{
        console.log(`收到${sock.remotePort}的数据:`+data.toString())
        WSRPCServer.publish('l',{f:'n',x:data.toString()})
    })
    sock.on('close',()=>{
        console.log(`链接关闭:${sock.remotePort}`)
        delete socks[sock.remotePort];
    })
    sock.on('error',()=>{

    })
    socks[sock.remotePort]=sock;
})
// 每隔1s时间发送一次数据
// setInterval(()=>{
//     for(let x of Object.values(socks)){
//         // console.log(`给${x.remotePort}发送:${Date.now()}`)
//         x.write('你是:'+x.remotePort+' 现在时间:'+Date.now());
//     }

// },1000)
server.on('error',()=>{

})
// 监听服务关闭
server.on('close',(data)=>{

})
// 启动服务端监听
server.listen(9001,'0.0.0.0');
console.log('服务已启动，端口:'+9001)

export default socks;